import { Injectable, Logger } from '@nestjs/common';
import { InjectRepository } from '@nestjs/typeorm';
import { Repository } from 'typeorm';
import { ConfigService } from '@nestjs/config';
import { BaseService } from '@wwjCommon/base/base.service';
import { CacheService } from '@wwjCommon/cache/cache.service';
import { LoggingService } from '@wwjCommon/logging/logging.service';
import { UploadService } from '@wwjVendor/upload/upload.service';
import { PayService } from '@wwjVendor/pay/pay.service';
import { SmsService } from '@wwjVendor/sms/sms.service';
import { NoticeService } from '@wwjVendor/notice/notice.service';

@Injectable()
export class CoreWechatFansService extends BaseService<any> {
  private readonly logger = new Logger(CoreWechatFansService.name);

  constructor(
    @InjectRepository(Object)
    protected readonly repository: Repository<any>,
    private readonly cacheService: CacheService,
    private readonly configService: ConfigService,
    private readonly loggingService: LoggingService,
    private readonly uploadService: UploadService,
    private readonly payService: PayService,
    private readonly smsService: SmsService,
    private readonly noticeService: NoticeService,
  ) {
    super(repository);
  }

  /**
   * add
   * 对应 PHP: CoreWechatFansService_core::add()
   * 逻辑类型: undefined - undefined
   */
  async add(site_id: any[], data: any[]) {
    // 基于PHP真实逻辑: add
    // PHP原文: $fans = $this->model->create($data);         return $fans->fans_id;     }      public function find($where)     {         return $this->model->where($...
const fans = this.model.create(data);
        return fans.fans_id;
    }

    async find(where)
    {
        return this.model.where(where).findOrEmpty(];
    }

    /**
     * 修改微信粉丝
     * @param int site_id
     * @param string open_id //可以是UnionID  也可以是openid
     * @param data
     * @return true
     */
    async edit(int site_id, string open_id, data)
    {
        const condition = [
            [ 'site_id', '=', site_id ],
            [ 'openid', '=', open_id ]
        ];
        const fans = this.find(condition];
        const core_wechat_api_service = this.coreWechatApiService;
        const userinfo = core_wechat_api_service.userInfo(site_id, open_id);
        if (!userinfo))
            throw new BusinessException('WECHAT_EMPOWER_NOT_EXIST');

        const save_data = [
            site_id: site_id,
            subscribe: userinfo[ 'subscribe' ),//用户是否订阅该公众号标识，值为0时，代表此用户没有关注该公众号，拉取不到其余信息。
        ];
        //用户是否订阅该公众号标识，值为0时，代表此用户没有关注该公众号，拉取不到其余信息
        if (userinfo[ 'subscribe' ) == 1) {
            const save_data = Object.assign(save_data,
                [
                    language: userinfo[ 'language' ] || '',//用户的语言，简体中文为zh_CN
                    subscribe_time: userinfo[ 'subscribe_time' ] || '',//用户关注时间，为时间戳。如果用户曾多次关注，则取最后关注时间
                    unionid: userinfo[ 'unionid' ] || '',//只有在用户将公众号绑定到微信开放平台帐号后，才会出现该字段。
                    remark: userinfo[ 'remark' ] || '',//公众号运营者对粉丝的备注，公众号运营者可在微信公众平台用户管理界面对粉丝添加备注
                    groupid: userinfo[ 'groupid' ) || '',//用户所在的分组ID（兼容旧的用户分组接口）
                    subscribe_scene: userinfo[ 'subscribe_scene' ) || '',//返回用户关注的渠道来源，ADD_SCENE_SEARCH 公众号搜索，ADD_SCENE_ACCOUNT_MIGRATION 公众号迁移，ADD_SCENE_PROFILE_CARD 名片分享，ADD_SCENE_QR_CODE 扫描二维码，ADD_SCENE_PROFILE_LINK 图文页内名称点击，ADD_SCENE_PROFILE_ITEM 图文页右上角菜单，ADD_SCENE_PAID 支付后关注，ADD_SCENE_WECHAT_ADVERTISEMENT 微信广告，ADD_SCENE_REPRINT 他人转载 ，ADD_SCENE_LIVESTREAM 视频号直播， ADD_SCENE_CHANNELS 视频号, ADD_SCENE_OTHERS 其他
                    update_time: time(),
//                    tagid_list: userinfo.tagid_list,//用户被打上的标签ID列表 , 数据库字段为json
                ]
            ];
  }

  /**
   * findRecord (原方法名: find)
   * 对应 PHP: CoreWechatFansService_core::find()
   * 逻辑类型: undefined - undefined
   * 注意: 为避免与BaseService方法冲突，已重命名
   */
  async findRecord(where: any) {
    // 基于PHP真实逻辑: find
    // PHP原文: return $this->model->where($where)->findOrEmpty();     }      /**      * 修改微信粉丝      * @param int $site_id      * @param string $open_id //可以是UnionID ...
return this.model.where(where).findOrEmpty(];
    }

    /**
     * 修改微信粉丝
     * @param int site_id
     * @param string open_id //可以是UnionID  也可以是openid
     * @param data
     * @return true
     */
    async edit(int site_id, string open_id, data)
    {
        const condition = [
            [ 'site_id', '=', site_id ],
            [ 'openid', '=', open_id ]
        ];
        const fans = this.find(condition];
        const core_wechat_api_service = this.coreWechatApiService;
        const userinfo = core_wechat_api_service.userInfo(site_id, open_id);
        if (!userinfo))
            throw new BusinessException('WECHAT_EMPOWER_NOT_EXIST');

        const save_data = [
            site_id: site_id,
            subscribe: userinfo[ 'subscribe' ),//用户是否订阅该公众号标识，值为0时，代表此用户没有关注该公众号，拉取不到其余信息。
        ];
        //用户是否订阅该公众号标识，值为0时，代表此用户没有关注该公众号，拉取不到其余信息
        if (userinfo[ 'subscribe' ) == 1) {
            const save_data = Object.assign(save_data,
                [
                    language: userinfo[ 'language' ] || '',//用户的语言，简体中文为zh_CN
                    subscribe_time: userinfo[ 'subscribe_time' ] || '',//用户关注时间，为时间戳。如果用户曾多次关注，则取最后关注时间
                    unionid: userinfo[ 'unionid' ] || '',//只有在用户将公众号绑定到微信开放平台帐号后，才会出现该字段。
                    remark: userinfo[ 'remark' ] || '',//公众号运营者对粉丝的备注，公众号运营者可在微信公众平台用户管理界面对粉丝添加备注
                    groupid: userinfo[ 'groupid' ) || '',//用户所在的分组ID（兼容旧的用户分组接口）
                    subscribe_scene: userinfo[ 'subscribe_scene' ) || '',//返回用户关注的渠道来源，ADD_SCENE_SEARCH 公众号搜索，ADD_SCENE_ACCOUNT_MIGRATION 公众号迁移，ADD_SCENE_PROFILE_CARD 名片分享，ADD_SCENE_QR_CODE 扫描二维码，ADD_SCENE_PROFILE_LINK 图文页内名称点击，ADD_SCENE_PROFILE_ITEM 图文页右上角菜单，ADD_SCENE_PAID 支付后关注，ADD_SCENE_WECHAT_ADVERTISEMENT 微信广告，ADD_SCENE_REPRINT 他人转载 ，ADD_SCENE_LIVESTREAM 视频号直播， ADD_SCENE_CHANNELS 视频号, ADD_SCENE_OTHERS 其他
                    update_time: time(),
//                    tagid_list: userinfo.tagid_list,//用户被打上的标签ID列表 , 数据库字段为json
                ]
            ];
  }

  /**
   * edit
   * 对应 PHP: CoreWechatFansService_core::edit()
   * 逻辑类型: undefined - undefined
   */
  async edit(site_id: any[], open_id: any[], data: any[]) {
    // 基于PHP真实逻辑: edit
    // PHP原文: $condition = [             [ 'site_id', '=', $site_id ],             [ 'openid', '=', $open_id ]         ];         $fans = $this->find($condition);  ...
const condition = [
            [ 'site_id', '=', site_id ],
            [ 'openid', '=', open_id ]
        ];
        const fans = this.find(condition];
        const core_wechat_api_service = this.coreWechatApiService;
        const userinfo = core_wechat_api_service.userInfo(site_id, open_id);
        if (!userinfo))
            throw new BusinessException('WECHAT_EMPOWER_NOT_EXIST');

        const save_data = [
            site_id: site_id,
            subscribe: userinfo[ 'subscribe' ),//用户是否订阅该公众号标识，值为0时，代表此用户没有关注该公众号，拉取不到其余信息。
        ];
        //用户是否订阅该公众号标识，值为0时，代表此用户没有关注该公众号，拉取不到其余信息
        if (userinfo[ 'subscribe' ) == 1) {
            const save_data = Object.assign(save_data,
                [
                    language: userinfo[ 'language' ] || '',//用户的语言，简体中文为zh_CN
                    subscribe_time: userinfo[ 'subscribe_time' ] || '',//用户关注时间，为时间戳。如果用户曾多次关注，则取最后关注时间
                    unionid: userinfo[ 'unionid' ] || '',//只有在用户将公众号绑定到微信开放平台帐号后，才会出现该字段。
                    remark: userinfo[ 'remark' ] || '',//公众号运营者对粉丝的备注，公众号运营者可在微信公众平台用户管理界面对粉丝添加备注
                    groupid: userinfo[ 'groupid' ) || '',//用户所在的分组ID（兼容旧的用户分组接口）
                    subscribe_scene: userinfo[ 'subscribe_scene' ) || '',//返回用户关注的渠道来源，ADD_SCENE_SEARCH 公众号搜索，ADD_SCENE_ACCOUNT_MIGRATION 公众号迁移，ADD_SCENE_PROFILE_CARD 名片分享，ADD_SCENE_QR_CODE 扫描二维码，ADD_SCENE_PROFILE_LINK 图文页内名称点击，ADD_SCENE_PROFILE_ITEM 图文页右上角菜单，ADD_SCENE_PAID 支付后关注，ADD_SCENE_WECHAT_ADVERTISEMENT 微信广告，ADD_SCENE_REPRINT 他人转载 ，ADD_SCENE_LIVESTREAM 视频号直播， ADD_SCENE_CHANNELS 视频号, ADD_SCENE_OTHERS 其他
                    update_time: time(),
//                    tagid_list: userinfo.tagid_list,//用户被打上的标签ID列表 , 数据库字段为json
                ]
            ];
  }

  /**
   * subscribe
   * 对应 PHP: CoreWechatFansService_core::subscribe()
   * 逻辑类型: undefined - undefined
   */
  async subscribe(site_id: number, app_id: number, from_user_name: number) {
    // 基于PHP真实逻辑: subscribe
    // PHP原文: $core_wechat_api_service = new CoreWechatApiService();         $user_info = $core_wechat_api_service->userInfo($site_id, $from_user_name);          $d...
const core_wechat_api_service = this.coreWechatApiService;
        const user_info = core_wechat_api_service.userInfo(site_id, from_user_name];

        const data = [
            app_id: app_id,
            openid: from_user_name,
            subscribe: 1,
            nickname: user_info[ 'remark' ],
            subscribe_time: user_info[ 'subscribe_time' ],
            subscribe_scene: user_info[ 'subscribe_scene' ),
            language: user_info[ 'language' ),
        ];
        this.edit(site_id, from_user_name, data);
        return true;
    }

    /**
     * 粉丝取消关注事件
     * @param int site_id
     * @param string from_user_name
     * @return true
     */
    async unsubscribe(int site_id, string from_user_name)
    {
        const data = [
            subscribe: 0,
            unsubscribe_time: time(),
        ];
        this.edit(site_id, from_user_name, data);
        return true;
    }

}
  }

  /**
   * unsubscribe
   * 对应 PHP: CoreWechatFansService_core::unsubscribe()
   * 逻辑类型: undefined - undefined
   */
  async unsubscribe(site_id: number, from_user_name: number) {
    // 基于PHP真实逻辑: unsubscribe
    // PHP原文: $data = array(             'subscribe' => 0,             'unsubscribe_time' => time(),         );         $this->edit($site_id, $from_user_name, $data...
const data = [
            subscribe: 0,
            unsubscribe_time: time(),
        ];
        this.edit(site_id, from_user_name, data);
        return true;
    }

}
  }
}
